package com.ibm.interfaces;

import java.util.Collection;

import com.ibm.util.exception.CPSException;

public interface IMessageClient {
	public void close();

	public void publishMessage(String destination, String message) throws CPSException;

	public void publishMessage(String topicName, byte[] message) throws CPSException;

	public void subscribe(String topicName) throws CPSException;

	public void unsubscribe(String topic) throws CPSException;

	public Collection<String> consumeMessage() throws CPSException;
}
